package com.gientech.springstream.handler;

import com.gientech.springstream.ingration.Sink;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Service;

@Service
@EnableBinding(Sink.class)
public class MessageSinkHandler {
    @StreamListener(Sink.INPUT)
    public void handle(Message<String> msg){
        System.out.println("receive msg:"+msg);
    }
}
